package com.hudsonmq.spring.impl.consume;

import com.hudson.codec.domain.MessageExt;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Author: 渔小鲤
 * @DateTime: 2025/7/12 14:07
 **/
public abstract class AbstractHudsonMQListener<T> implements HudsonMQHandler {
    private static final Logger logger = LoggerFactory.getLogger(AbstractHudsonMQListener.class);

    static ConcurrentHashMap<String, HudsonMQHandler> HANDLER_MAP = new ConcurrentHashMap<>();

    @Override
    public void onMessage(byte[] message) throws Exception {

    }

    @Override
    public void retry(List<MessageExt> message) {

    }
}
